搜索资源列表
kafka28
- 我在学习java的时候，老师编写的一些代码，比较基础-kafka
KafkaDemo
- Kafka是一个高吞吐量分布式消息系统。linkedin开源的kafka。 Kafka就跟这个名字一样，设计非常独特。首先，kafka的开发者们认为不需要在内存里缓存什么数据，操作系统的文件缓存已经足够完善和强大，只要你不搞随机写，顺序读写的性能是非常高效的。kafka的数据只会顺序append，数据的删除策略是累积到一定程度或者超过一定时间再删除。Kafka另一个独特的地方是将消费者信息保存在客户端而不是MQ服务器，这样服务器就不用记录消息的投递过程，每个客户端都自己知道自己下一次应该从什么地
flume-kafka-storm-sunxing
- 一个基于storm+flume+kafka的可运行程序包(A storm+flume+kafka based executable package)
sticky-menu
- Sticy menu in wpf Technologies you should be comfortable with or interested in learning: Scala, AKKA, Spark, Kafka, Java, SQL, Groovy, Casandra, SQL, REST API's, Swagger, MemCacheD, Couchbase (NoSQL), Redis, Protobuf, and infrastructure/tools like O
TestSend
- Java的kafka中间件测试发送,在里面配置号ip端口等就可以测试(Java's Kafka middleware test is sent, and the inside configuration number IP port can be tested.)
JavaKafkaConsumerHighAPI
- 自定义简单Kafka消费者,里面有对kafka的简单引用(Customize simple Kafka consumers with a simple reference to Kafka)
flume-es-sink.tar
- kafka0.10->flume1.8->elasticsearch 6.0 自定义日志解析类，自定义索引名,Kafkasource 修改从最后ｏｆｆｓｅｔ开始读。 (Kafka 0.10 to flume 1.8 to elasticsearch 6 Customize the log parsing class, customize the index name, and read the Kafkasource changes from the last offset.)
kafka
- kafka客户端例子,包括jass验证。用于调试(emmmmsadffffffffdsadsfdasf)
MqttWk库
- MQTWTK是基于NutZBoo+NeTy+ReiS+卡夫卡（可选）的Java MQTT代理，代理支持QoS 0、QoS 1和QoS 2，它使用NETY作为协议编码和解码部分，使用NutZBoW提供依赖注入和属性配置，使用ReDIS实现消息缓存。和集群，并使用Kafka实现消息代理。